package com.intct.common;

/**
 * @author gufg
 * @since 2025-09-17 14:55
 */
public class Constant {
    public static final String FLINK_CDC_MYSQL_JSON_SOURCE_KEY = "source";
    public static final String FLINK_CDC_MYSQL_JSON_FILE_KEY = "file";
    public static final String FLINK_CDC_MYSQL_JSON_POS_KEY = "pos";
    public static final String FLINK_CDC_MYSQL_JSON_DB_KEY = "db";
    public static final String FLINK_CDC_MYSQL_JSON_TABLE_KEY = "table";
    public static final String FLINK_CDC_MYSQL_JSON_TS_MS_KEY = "ts_ms";

    public static final String FLINK_CDC_MYSQL_JSON_OP_KEY = "op";

    public static final String FLINK_CDC_MYSQL_JSON_AFTER_KEY = "after";

    public static final String FLINK_CDC_MYSQL_JSON_BEFORE_KEY = "before";
    public static final String FLINK_CDC_MYSQL_JSON_TTRASACTION_KEY = "transaction";

    public static final String KAFKA_DB_ODS_TOPIC_NAME = "ods-db";

    public static final String KAFKA_LOCUS_ODS_TOPIC_NAME = "ods_locus";
}
